//mysql连接池配置文件
const mysql = require("mysql");
const sql = require("./sql.js");
const ELEjson = require("./ELEjson.js");
const $dbConfig = require("./dbConfig.js");
const db1 = mysql.createPool($dbConfig.db1); // 使用连接池，避免开太多的线程，提升性能
const { promisify } = require("util");
// 将 pool.query 方法转换为返回 Promise 的方法
const db1_Query = promisify(db1.query).bind(db1);
let getMysqlData = async (table) => {
  try {
    let sqlString = sql[table].queryAll;
    // 查询数据库
    const resultS = await db1_Query(sqlString);
    const _result = { result: "select", data: resultS };
    return ELEjson(_result);
    //   return { code: 200, data: resultS }; // 将结果返回给渲染进程
  } catch (error) {
    console.error("数据库查询出错:", error);
    return ELEjson("err", error);
  }
};

module.exports = {
  getMysqlData,
};
